package com.example.bootDemo.config;

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @description: 定义队列
 * @author: zys
 * @create: 2021-04-09 17:20
 **/
@Configuration
public class RabbitMqConfig {

    /**
     * 简单模式：一个生产者，一个消费者
     */
    @Bean
    public Queue queue() {
        return new Queue("hello");
    }

    /**
     * work模式：一个生产者，多个消费者，每个消费者获取到的消息唯一
     */
    @Bean
    public Queue oneToManyQueue() {
        return new Queue("oneToMany");
    }

    /**
     * 发送对象
     */
    @Bean
    public Queue ObjectQueue() {
        return new Queue("object");
    }


}
